// 这是一台模拟的物联网设备，设备会连接到物联网平台，并且会忘指定的主题推送物联网数据
const mqtt = require('mqtt');
const client  = mqtt.connect('mqtt://broker-cn.emqx.io:1883');

client.on('connect', function () {
});


client.on('message', (topic, message) => {
    console.log(message.toString());
});

// 模拟发送物联网数据，1秒发送一次，实际情况没这么快
setInterval(() => {
    client.publish('iot/data', JSON.stringify({
        deviceId: '123456', // 设备id
        time: new Date().getTime(),// 数据上传的时间戳
        wd: parseFloat((Math.random()*5).toFixed(1)), // 模拟的物联网数据，温度
        sd: parseInt((Math.random()*20 + 50).toFixed(0)), // 模拟的物联网数据，湿度
    }))
}, 1000)
